import pika

credentials = pika.PlainCredentials("guest","guest")
connection = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1',credentials=credentials))
channel = connection.channel()

channel.queue_declare(queue='TEST02')

channel.basic_publish(exchange='',
                      routing_key='TEST02',
                      body='Hello World22333!')
print(" [x] Sent 'Hello World!'")
